package com.xw.base.service.impl;

import com.xw.base.entity.basetask.BaseTask;
import com.xw.base.service.BaseService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.util.StringUtils;

/**
 * mongodb的基础增删改一套，希望基础该类，可以直接使用
 *
 * @author xiongwei_vendor
 * @date 2021/10/29 10:57
 */
@Slf4j
public class BaseServiceImpl implements BaseService {

    @Autowired
    private MongoTemplate mongoTemplate;


    public boolean deleteTask(String taskId) {
//        if (StringUtils.isEmpty(taskId)) {
//            log.info("delete task error , taskId is null");
//            return false;
//        }
//
//        Criteria criteria = Criteria.where("taskId").is(taskId);
//        Query query = new Query(criteria);
//        T t = mongoTemplate.findOne(query, entityClass);
//        if (t == null) {
//            log.info("delete task error , 不能找到改任务id的信息");
//            return false;
//        }
//        mongoTemplate.remove(query,entityClass);
        return true;
    }

    @Override
    public boolean insertTask(BaseTask baseTask) {
        log.info("插入失败,baseTask = {}",baseTask.toString());
        return true;
    }

//    @Override
//    public boolean insertTask(BaseTask baseTask) {
//        if (null == baseTask) {
//            log.info("插入失败，插入的值为null");
//            return false;
//        }
//        mongoTemplate.insert(baseTask);
//        return true;
//    }

    @Override
    public void test() {
        log.info("这是test");
    }

}
